package com.smart.redis.pubsub;

import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import com.smart.redis.client.RedisClient;

import redis.clients.jedis.Jedis;
/**
 * 
* @ClassName: Redis2PubSub 
* @Description: TODO 订阅/发布实例
* @Company:e-smart.top
* @author Thinkpad 
* @version 1.0 2018年8月31日 下午6:00:24
 */
public class Redis2PubSub {
	
    Jedis jedis;

    @Before//test方法执行之前执行
    public void init(){
        jedis = RedisClient.getJedis();
    }
    @After//test方法执行之后执行
    public void destroy(){
    	RedisClient.returnToPool(jedis);
    }
    
    @Test//先订阅在发布消息
    public void test(){
    	jedis.subscribe(new Subscriber(), "china-1","china-2","china-3");
    }
    
    /*
     * 测试发布消息
     */
    @Test//发布者1
    public void test1(){
        jedis.publish("china-1", "日了狗了！！");
    }
    @Test//发布者2
    public void test2(){
        jedis.publish("china-2", "红杏出墙了！！");
    }
    @Test//发布者3
    public void test3(){
        jedis.publish("china-3", "比赛GG了！！");
    }
}
